package sicnu.cs.ich.rocketmq.config;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;

/**
 * @author CaiKe
 * @date 2021/12/1 23:18
 */
@Data
@ConfigurationProperties(prefix = "rocketmq")
public class RocketMQProperties {
    private boolean isEnable = false;
    private String namesrvAddr = "139.9.244.223:9876";
    private String groupName = "default";
    private int producerMaxMessageSize = 1024;
    private int producerSendMsgTimeout = 2000;
    private int producerRetryTimesWhenSendFailed = 2;
    private int consumerConsumerThreadMin = 5;
    private int consumerConsumerThreadMax = 30;
    private int consumerConsumeMessageBatchMaxSize = 1;
    //省略get set
}